package com.imooc.ecommerce.sink;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * <p>自定义物流信息接收器(Sink)
 *
 * @author Yaxi.Zhang
 * @since 2022/11/17 20:14
 */
public interface LogisticsSink {

    /**
     * 输入信道名称
     */
    String INPUT = "logisticsInput";

    /**
     * <p>物流 Sink -> logisticsInput
     */
    @Input(LogisticsSink.INPUT)
    SubscribableChannel logisticsInput();

}
